#ifndef _TASKQUEUE_
#define _TASKQUEUE_
#include<func.h>
typedef struct task_s{
    int netfd;
    struct task_s *pNext;
} task_t;

typedef struct taskQueue_s{
    task_t *pFront;
    task_t *pRear;
    int queueSize;//当前任务队列的长度
    pthread_mutex_t mutex;
    pthread_cond_t cond;
} taskQueue_t;

int taskQueueInit(taskQueue_t *taskQueue);
int EntaskQueue(taskQueue_t *taskQueue, int vfd);
int DetaskQueue(taskQueue_t *taskQueue);

#endif